第1章
课程导学
风控场景概述 · Flink CEP能解决什么 · 课程目标与前置知识
导学总览
第2章
Flink基础回顾
Flink架构 · 核心概念(DataStream/时间语义/Watermark) · 环境搭建
基础回顾
第3章
CEP概念入门
什么是复杂事件处理 · CEP vs 普通流处理 · 核心术语(事件/模式/匹配)
概念入门
第4章
Flink CEP核心API
Pattern API详解 · 个体模式(Single Pattern) · 组合模式
API核心
第5章
Flink CEP核心API (续)
模式序列(严格/宽松/非确定宽松) · 循环模式
序列循环
第6章
Flink CEP核心API (续)
条件(Conditions) · 时间限制(Within) · 匹配后跳过策略
条件跳过
第7章
Flink CEP核心API (续)
PatternStream · Select/FlatSelect · 超时事件处理
超时Select
第8章
风控场景分析
常见风控场景(登录/交易/营销反作弊) · 规则特征与挑战
风控场景
第9章
实战项目一：登录风控 (上)
需求分析 · 暴力破解/异地登录/异常设备检测
登录需求
第10章
实战项目一：登录风控 (中)
数据模型设计 · 登录事件/用户画像 · Kafka接入
数据Kafka
第11章
实战项目一：登录风控 (下) CEP规则
5分钟连续失败3次 · 不同城市/新设备模式
规则CEP
第12章
实战项目一：登录风控 (下) 告警处置
告警消息格式 · Redis/ES存储 · 限流封禁
告警处置
第13章
实战项目二：交易风控 (上)
需求分析 · 盗刷/小额试探/大额异常检测
交易需求
第14章
实战项目二：交易风控 (中)
数据模型 · 交易事件/风险等级/历史行为窗口
模型标签
第15章
实战项目二：交易风控 (下) CEP规则
高频小额 · 大额偏离历史行为模式
规则偏离
第16章
实战项目二：交易风控 (下) 动态规则
Nacos/Apollo动态加载 · 规则热更新机制
动态热更新
第17章
实战项目三：营销反作弊 (上)
需求分析 · 薅羊毛/刷单/虚假流量检测
反作弊营销
第18章
实战项目三：营销反作弊 (中)
数据模型 · 活动事件/设备指纹/IP信誉库
指纹IP
第19章
实战项目三：营销反作弊 (下) CEP规则
多账号领券 · 同IP高频 · 跨活动参与
规则高频
第20章
实战项目三：营销反作弊 (下) 规则编排
规则优先级 · 依赖 · AND/OR/NOT组合
编排复杂
第21章
状态管理与容错
CEP状态存储 · Checkpoint/Savepoint · 故障恢复
状态容错
第22章
性能优化 (上)
并行度 · 模式剪枝 · 避免状态膨胀
优化剪枝
第23章
性能优化 (下)
Side Output分流 · 事件时间vs处理时间 · 数据倾斜
分流倾斜
第24章
CEP与机器学习结合
风控评分卡 · CEP输出作为特征 · Flink ML联动
ML评分卡
第25章
CEP与规则引擎(Drools)集成
规则引擎选型 · CEP触发Drools · 混合架构
Drools集成
第26章
CEP可视化与监控
规则命中率/延迟监控 · 告警链路追踪
监控可视化
第27章
CEP测试与验证
单元测试(CEPTestHarness) · 集成测试 · 回放测试
测试回放
第28章
生产环境部署
Flink on YARN/K8s · 资源规划 · 灰度发布
部署K8s
第29章
案例复盘
某电商双11风控实战 · 踩坑记录与解决方案
复盘双11
第30章
课程总结与展望
CEP技术趋势 · Flink 2.0展望 · 学习路径建议
总结趋势